google.golang.org/grpc.addrConnStream.transportStream (field)

14 uses

	google.golang.org/grpc (current package)
		stream.go#L1326: 	as.transportStream = s
		stream.go#L1353: 	transportStream  *transport.ClientStream
		stream.go#L1377: 	m, err := as.transportStream.Header()
		stream.go#L1385: 	return as.transportStream.Trailer()
		stream.go#L1395: 	as.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
		stream.go#L1404: 	return as.transportStream.Context()
		stream.go#L1445: 	if err := as.transportStream.Write(hdr, payload, &transport.WriteOptions{Last: !as.desc.ClientStreams}); err != nil {
		stream.go#L1468: 		if ct := as.transportStream.RecvCompress(); ct != "" && ct != encoding.Identity {
		stream.go#L1482: 	if err := recv(as.parser, as.codec, as.transportStream, as.decompressorV0, m, *as.callInfo.maxReceiveMessageSize, nil, as.decompressorV1, false); err != nil {
		stream.go#L1484: 			if statusErr := as.transportStream.Status().Err(); statusErr != nil {
		stream.go#L1499: 	if err := recv(as.parser, as.codec, as.transportStream, as.decompressorV0, m, *as.callInfo.maxReceiveMessageSize, nil, as.decompressorV1, false); err == io.EOF {
		stream.go#L1500: 		return as.transportStream.Status().Err() // non-server streaming Recv returns nil on success
		stream.go#L1518: 	if as.transportStream != nil {
		stream.go#L1519: 		as.transportStream.Close(err)